package com.ls.mq.listener.impl;

import org.apache.log4j.Logger;

import com.ls.mq.iterface.MessageListener;
/**
 * 做一些默认处理
 * @author Administrator
 *
 */
public class DefaultQueueMessageListener implements MessageListener{
	Logger logger = Logger.getLogger(DefaultQueueMessageListener.class);
	@Override
	public void doMessage(String channel, String msg) {
		logger.info(String.format("收到来自Queue的消息 %s : %s", channel,msg));
	}

}
